package com.cy.核心编程.thead.basic.yellow;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;

public class Test {
    public static void main(String[] args) {
        BlockingQueue<Video> videos = new LinkedBlockingDeque<Video>();

        ReadVideoThread rvt1 = new ReadVideoThread(videos);
        ReadVideoThread rvt2 = new ReadVideoThread(videos);
        ReadVideoThread rvt3 = new ReadVideoThread(videos);

        SendVideoThread svt1 = new SendVideoThread(videos);
        SendVideoThread svt2 = new SendVideoThread(videos);

        rvt1.start();
        rvt2.start();
        rvt3.start();

        svt1.start();
        svt2.start();
    }
}
